package com.lzhsite.mapreduce.sort;


import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.mapreduce.Partitioner;
/**
 * 自定义分区
 * @author Administrator
 * 2018年5月31日上午8:20:58
 */
public class DefinedPartition extends Partitioner<CombinationKey, IntWritable>{
	/**
	 * @param key map输出，这里根据组合键的第一个值进行分区
	 * @param value map输出的key
	 * @param numPartitions 分区总数，即reduce的个数
	 */
	@Override
	public int getPartition(CombinationKey key, IntWritable value, int numPartitions) {
		return (key.getFirstKey().hashCode()&Integer.MAX_VALUE)%numPartitions;
	}
 
}